package com.nepu.spark.realtime.constant

/**
  * @author chenshuaijun
  * @create 2022-10-29 19:19
  */
object KafkaConstant {

  // bootstrap
  val BOOTSTRAP_SERVER: String = "bootstrap.servers"
  // ods层日志文件的topic
  val ODS_BASE_LOG_TOPIC: String = "ODS_BASE_LOG_1018"
  /*==================以下是ODS层日志数据分流所使用到的topic==========================*/
  //启动主题
  val DWD_START_LOG: String = "DWD_START_LOG"
  //页面访问主题
  val DWD_PAGE_LOG: String = "DWD_PAGE_LOG"
  //页面动作主题
  val DWD_PAGE_ACTION: String = "DWD_PAGE_ACTION"
  //页面曝光主题
  val DWD_PAGE_DISPLAY: String = "DWD_PAGE_DISPLAY"
  //错误主题
  val DWD_ERROR_INFO: String = "DWD_ERROR_INFO"
  // ods层业务数据的topic
  val ODS_BASE_DB_TOPIC: String = "ODS_BASE_DB"

  /* ==================以下是动态表清单对应的topic====================================*/
  val FACT_TABLE_NAME: String = "FACT_TABLE_NAME"
  val DIM_TABLE_NAME: String = "DIM_TABLE_NAME"
}
